package cn.tx.receive;

/**
 * @author Mxb
 * @version 1.0
 * @date 2020/10/12 22:30
 */
////不签收
//@Component
//public class MessageReceive3 {
//    @RabbitListener(bindings = {
//            @QueueBinding(value = @Queue("queue"),
//                    key = "error",
//                    exchange = @Exchange(value = "directs"))//默认的直连交换机
//    })
//    public void receiveMessage(String content, Message message, Channel channel) throws
//            IOException {
//        System.out.println("===============开始消费==================");
//        System.out.println("content: "+content);
//        long deliveryTag = message.getMessageProperties().getDeliveryTag();//消息投递ID
//        System.out.println("消息投递ID: " + deliveryTag);
//        String messageId = message.getMessageProperties().getMessageId();
//        System.out.println("消息自定义ID: " + messageId);
//        if (content.equals("123456")) {//如果消息内容为123456 就签收它
//            /**
//             * 参数说明:
//             * deliveryTag 消息投递ID，要签收的投递ID 是多少
//             * multiple:是否批量签收
//             */
//            channel.basicAck(deliveryTag, false);
//            System.out.println("消息签收成功");
//        } else {
//            //如果不是123456 就拒绝签收
//            /**
//             * 参数说明:
//             * deliveryTag 消息投递ID，要签收的投递ID 是多少
//             * multiple:是否批量签收
//             * requeue: true 代表拒绝签收并把消息重新放回到队列里面false 就直接拒绝
//             */
//            channel.basicNack(deliveryTag, false, true);
//            System.out.println("消息被拒绝签收");
//        }
//        System.out.println("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~");
//    }
//}
